package com.heima.stream.processor;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

/**
 * 处理器接口：指定数据从何而来（数据来源话题），去往何处（处理后数据话题）
 */
public interface WordProcess {

    /**
     * 指定数据来源话题  数据从何而来 从某个话题中
     * @return
     */
    @Input("words_1_input")
    public KStream<String, String> input();


    /**
     * 处理后目的地话题   数据去往何处：另一个计算后的话题
     * @return
     */
    @Output("counts_1_output")
    public KStream<String, String> output();
}